} sirinet_promise_status_t;
typedef struct sirinet_promise_s sirinet_promise_t;
-
-typedef struct sirinet_pkg_s sirinet_pkg_t;
typedef void (* sirinet_promise_cb)(
sirinet_promise_t * promise,
- sirinet_pkg_t * pkg,
+ void * data,
int status);
#include <uv.h>
forward->siridb->pools->pool + n,
pkg,
0,
- sirinet_promises_on_response,
+ (sirinet_promise_cb) sirinet_promises_on_response,
promises,
0))
{
siridb->replica,
siridb->replicate->initsync->pkg,
INITSYNC_TIMEOUT,
- INITSYNC_on_insert_response,
+ (sirinet_promise_cb) INITSYNC_on_insert_response,
siridb,
FLAG_KEEP_PKG);
}
siridb->pools->pool + n,
pkg,
INSERT_TIMEOUT,
- sirinet_promises_on_response,
+ (sirinet_promise_cb) sirinet_promises_on_response,
promises,
0))
{
server,
pkg,
0,
- on_ack_response,
+ (sirinet_promise_cb) on_ack_response,
handle,
0))
{
server,
pkg,
0,
- on_ack_response,
+ (sirinet_promise_cb) on_ack_response,
handle,
0))
{
pool,
pkg,
timeout,
- sirinet_promises_on_response,
+ (sirinet_promise_cb) sirinet_promises_on_response,
promises,
FLAG_KEEP_PKG | flags))
{
pool,
pkg,
timeout,
- sirinet_promises_on_response,
+ (sirinet_promise_cb) sirinet_promises_on_response,
promises,
FLAG_KEEP_PKG | flags))
{
siridb->reindex->server,
siridb->reindex->pkg,
REINDEX_TIMEOUT,
- REINDEX_on_insert_response,
+ (sirinet_promise_cb) REINDEX_on_insert_response,
siridb,
FLAG_KEEP_PKG);
}
siridb->replica,
pkg,
REPLICATE_TIMEOUT,
- REPLICATE_on_repl_response,
+ (sirinet_promise_cb) REPLICATE_on_repl_response,
siridb,
0))
{
siridb->replica,
pkg,
0,
- REPLICATE_on_repl_finished_response,
+ (sirinet_promise_cb) REPLICATE_on_repl_finished_response,
NULL,
0))
{
server,
pkg,
SIRIDB_SERVER_FLAGS_TIMEOUT,
- SERVER_on_flags_update_response,
+ (sirinet_promise_cb) SERVER_on_flags_update_response,
NULL,
0))
{
server,
pkg,
0,
- SERVER_on_auth_response,
+ (sirinet_promise_cb) SERVER_on_auth_response,
NULL,
0))
{
server,
pkg,
timeout,
- sirinet_promises_on_response,
+ (sirinet_promise_cb) sirinet_promises_on_response,
promises,
FLAG_KEEP_PKG))
{